package com.hk.rabbitmq.two;

import com.hk.rabbitmq.utils.RabbitMqUtils;
import com.rabbitmq.client.Channel;

import java.util.Scanner;

/**
 * @author: dpb
 * @date: 2022/3/11
 * 发送消息
 */
public class Task01 {

    private final static String QUEUE_NAME = "hello";

    public static void main(String[] args) throws  Exception{
        Channel channel = RabbitMqUtils.getChannel();

        /**
         * 1、队列的名称
         * 2、队列是否在重启之后存在
         * 3、该队列是否只供一个消费者进行消费 true为不共享 false为共享
         * 4、是否自动删除
         * 5、其他参数
         */
        channel.queueDeclare(QUEUE_NAME, false, true, false, null);

        Scanner scanner = new Scanner(System.in);
        while (scanner.hasNext()) {
            String message = scanner.next();
            /**
             * 1、要把消息发送到哪台交换机
             * 2、对应的路由的key
             * 3、消息的其他属性
             * 4、具体的消息体
             */
            channel.basicPublish("", QUEUE_NAME, null, message.getBytes());
            System.out.println("发送成功。。。" + message);
        }
    }
}
